package com.world.rickcloudendpoint.stream.filter;

import com.world.rickcloudendpoint.stream.message.Message;
import lombok.EqualsAndHashCode;
import lombok.Getter;

import java.util.ArrayList;
import java.util.List;

/**
 * @description: 过滤消息
 * @author: jlsong
 * @date: 2022/03/11 20:42:16
 * @version: 1.0
 */
@Getter
@EqualsAndHashCode
public class FilteredMessages {
    /**
     * 有效消息缓存器
     */
    private final List<Message> validMessages = new ArrayList<>();
    /**
     * 无效消息 缓存器
     */
    private final List<Message> invalidMessages = new ArrayList<>();

    /**
     * 增加消息到有效缓存器
     */
    public void addToValidMessages(Message message) {
        validMessages.add(message);
    }

    /**
     * 增加消息到无效缓存器
     */
    public void addToInvalidMessages(Message message) {
        invalidMessages.add(message);
    }

    /**
     * 获取有效消息缓存器容量
     */
    public int sizeOfValidMessages() {
        return validMessages.size();
    }

    /**
     * 获取无效消息缓存器容量
     */
    public int sizeOfInvalidMessages() {
        return invalidMessages.size();
    }
}
